package com.example.pro2_reactive_streams.DMB15_观察者模式.observer.pro4_guava;


import com.google.common.eventbus.Subscribe;

//观察者
public class GuavaEvent {

    //****加入此注解，表明此方法是回调方法    相当于前面的 update().
    @Subscribe  //注册   观察者1
    public void a(String value){
        //TODO: 1. 引入线程
        //      2. 引入线程池
//        try {
//            Thread.sleep(10000);
//        } catch (InterruptedException e) {
//            throw new RuntimeException(e);
//        }
        System.out.println("执行subscribe方法，传入的参数是：" + value);
        System.out.println("我是股市多头，我看涨股价，我要买入股票");
    }


    @Subscribe
    public void b(String value){    //观察者2的操作
        System.out.println("只要加了 @Subscribe 注解， 另一个被通知的方法：" + value);
        System.out.println("我是股市空头，我看跌股价，我要卖出股票");
    }

}
